package com.gis.bigdata.spark.streaming

import org.apache.spark.SparkConf
import org.apache.spark.streaming.dstream.{DStream, ReceiverInputDStream}
import org.apache.spark.streaming.{Seconds, StreamingContext}

/**
 * @author LnnuUser
 * @create 2021-09-03-下午7:40
 */
object Sparktreaming10_MockData {

  def main(args: Array[String]): Unit = {

    // 生成模拟数据
    // 时间戳 省份 城市 用户 广告

    // Application => Kafka => SparkStream

  }

}
